🎖️GitЯра🎖️
Node / meshtastic / Meshtastic-Android / files / feature / firmware / src / commonMain / kotlin / org / meshtastic / feature / firmware / ota / Esp32OtaUpdateHandler.kt
Displaying Raw • Download
feature/firmware/src/commonMain/kotlin/org/meshtastic/feature/firmware/ota/Esp32OtaUpdateHandler.kt renovate/net.java.dev.jna-jna-5.x (5a8f4966) Text, 14.75 KB
T8b949e/*
* Copyright (c) 2026 Meshtastic LLC
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
Tff7b72package T7ee787org.meshtastic.feature.firmware.ota
Tff7b72import T7ee787co.touchlab.kermit.Logger
Tff7b72import T7ee787kotlinx.coroutines.CancellationException
Tff7b72import T7ee787kotlinx.coroutines.delay
Tff7b72import T7ee787kotlinx.coroutines.withContext
Tff7b72import T7ee787org.koin.core.annotation.Single
Tff7b72import T7ee787org.meshtastic.core.ble.BleConnectionFactory
Tff7b72import T7ee787org.meshtastic.core.ble.BleScanner
Tff7b72import T7ee787org.meshtastic.core.common.util.CommonUri
Tff7b72import T7ee787org.meshtastic.core.common.util.NumberFormatter
Tff7b72import T7ee787org.meshtastic.core.common.util.ioDispatcher
Tff7b72import T7ee787org.meshtastic.core.database.entity.FirmwareRelease
Tff7b72import T7ee787org.meshtastic.core.di.CoroutineDispatchers
Tff7b72import T7ee787org.meshtastic.core.model.DeviceHardware
Tff7b72import T7ee787org.meshtastic.core.model.RadioController
Tff7b72import T7ee787org.meshtastic.core.repository.NodeRepository
Tff7b72import T7ee787org.meshtastic.core.resources.Res
Tff7b72import T7ee787org.meshtastic.core.resources.UiText
Tff7b72import T7ee787org.meshtastic.core.resources.firmware_update_connecting_attempt
Tff7b72import T7ee787org.meshtastic.core.resources.firmware_update_downloading_percent
Tff7b72import T7ee787org.meshtastic.core.resources.firmware_update_erasing
Tff7b72import T7ee787org.meshtastic.core.resources.firmware_update_extracting
Tff7b72import T7ee787org.meshtastic.core.resources.firmware_update_hash_rejected
Tff7b72import T7ee787org.meshtastic.core.resources.firmware_update_not_found_in_release
Tff7b72import T7ee787org.meshtastic.core.resources.firmware_update_ota_failed
Tff7b72import T7ee787org.meshtastic.core.resources.firmware_update_starting_ota
Tff7b72import T7ee787org.meshtastic.core.resources.firmware_update_uploading
Tff7b72import T7ee787org.meshtastic.core.resources.firmware_update_waiting_reboot
Tff7b72import T7ee787org.meshtastic.core.resources.getStringSuspend
Tff7b72import T7ee787org.meshtastic.feature.firmware.FirmwareArtifact
Tff7b72import T7ee787org.meshtastic.feature.firmware.FirmwareFileHandler
Tff7b72import T7ee787org.meshtastic.feature.firmware.FirmwareRetriever
Tff7b72import T7ee787org.meshtastic.feature.firmware.FirmwareUpdateHandler
Tff7b72import T7ee787org.meshtastic.feature.firmware.FirmwareUpdateState
Tff7b72import T7ee787org.meshtastic.feature.firmware.ProgressState
Tff7b72import T7ee787org.meshtastic.feature.firmware.stripFormatArgs
Tff7b72private Tff7b72const Tff7b72val Te6edf3RETRY_DELAY Tff7b72= T79c0ff2T79c0ff0T79c0ff0T79c0ff0L
Tff7b72private Tff7b72const Tff7b72val Te6edf3PERCENT_MAX Tff7b72= T79c0ff1T79c0ff0T79c0ff0
Tff7b72private Tff7b72const Tff7b72val Te6edf3KIB_DIVISOR Tff7b72= T79c0ff1T79c0ff0T79c0ff2T79c0ff4f
T8b949e// Time to wait for OTA reboot packet to be sent before disconnecting mesh service
Tff7b72private Tff7b72const Tff7b72val Te6edf3PACKET_SEND_DELAY_MS Tff7b72= T79c0ff2T79c0ff0T79c0ff0T79c0ff0L
T8b949e// Time to wait for BLE GATT to fully release after disconnecting mesh service
Tff7b72private Tff7b72const Tff7b72val Te6edf3GATT_RELEASE_DELAY_MS Tff7b72= T79c0ff1T79c0ff0T79c0ff0T79c0ff0L
T8b949e/**
* KMP handler for ESP32 firmware updates using the Unified OTA protocol. Supports both BLE and WiFi/TCP transports via
* [UnifiedOtaProtocol].
*
* All platform I/O (file reading, content-resolver imports) is delegated to [FirmwareFileHandler].
*/
Tf0883e@SuppressTb4b4b4(Ta5d6ff"Ta5d6ffTooManyFunctionsTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffLongParameterListTa5d6ff"Tb4b4b4)
Tf0883e@Single
Tff7b72class T56d364Esp32OtaUpdateHandlerTb4b4b4(
Tff7b72private Tff7b72val Te6edf3firmwareRetrieverTb4b4b4: Te6edf3FirmwareRetrieverTb4b4b4,
Tff7b72private Tff7b72val Te6edf3firmwareFileHandlerTb4b4b4: Te6edf3FirmwareFileHandlerTb4b4b4,
Tff7b72private Tff7b72val Te6edf3radioControllerTb4b4b4: Te6edf3RadioControllerTb4b4b4,
Tff7b72private Tff7b72val Te6edf3nodeRepositoryTb4b4b4: Te6edf3NodeRepositoryTb4b4b4,
Tff7b72private Tff7b72val Te6edf3bleScannerTb4b4b4: Te6edf3BleScannerTb4b4b4,
Tff7b72private Tff7b72val Te6edf3bleConnectionFactoryTb4b4b4: Te6edf3BleConnectionFactoryTb4b4b4,
Tff7b72private Tff7b72val Te6edf3dispatchersTb4b4b4: Te6edf3CoroutineDispatchersTb4b4b4,
Tb4b4b4) Tb4b4b4: Te6edf3FirmwareUpdateHandler Tb4b4b4{
T8b949e/** Entry point for FirmwareUpdateHandler interface. Routes to BLE (MAC with colons) or WiFi (IP without). */
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffstartUpdateTb4b4b4(
Te6edf3releaseTb4b4b4: Te6edf3FirmwareReleaseTb4b4b4,
Te6edf3hardwareTb4b4b4: Te6edf3DeviceHardwareTb4b4b4,
Te6edf3targetTb4b4b4: Tffa657StringTb4b4b4,
Te6edf3updateStateTb4b4b4: Tb4b4b4(Te6edf3FirmwareUpdateStateTb4b4b4) Tff7b72-Tff7b72> Tffa657UnitTb4b4b4,
Te6edf3firmwareUriTb4b4b4: Te6edf3CommonUri?Tb4b4b4,
Tb4b4b4)Tb4b4b4: Te6edf3FirmwareArtifact? Tff7b72= Tff7b72if Tb4b4b4(Te6edf3targetTb4b4b4.Te6edf3containsTb4b4b4(Ta5d6ff"Ta5d6ff:Ta5d6ff"Tb4b4b4)Tb4b4b4) Tb4b4b4{
Te6edf3startBleUpdateTb4b4b4(Te6edf3releaseTb4b4b4, Te6edf3hardwareTb4b4b4, Te6edf3targetTb4b4b4, Te6edf3updateStateTb4b4b4, Te6edf3firmwareUriTb4b4b4)
Tb4b4b4} Tff7b72else Tb4b4b4{
Te6edf3startWifiUpdateTb4b4b4(Te6edf3releaseTb4b4b4, Te6edf3hardwareTb4b4b4, Te6edf3targetTb4b4b4, Te6edf3updateStateTb4b4b4, Te6edf3firmwareUriTb4b4b4)
Tb4b4b4}
Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffstartBleUpdateTb4b4b4(
Te6edf3releaseTb4b4b4: Te6edf3FirmwareReleaseTb4b4b4,
Te6edf3hardwareTb4b4b4: Te6edf3DeviceHardwareTb4b4b4,
Te6edf3addressTb4b4b4: Tffa657StringTb4b4b4,
Te6edf3updateStateTb4b4b4: Tb4b4b4(Te6edf3FirmwareUpdateStateTb4b4b4) Tff7b72-Tff7b72> Tffa657UnitTb4b4b4,
Te6edf3firmwareUriTb4b4b4: Te6edf3CommonUri? Tff7b72= Tff7b72nullTb4b4b4,
Tb4b4b4)Tb4b4b4: Te6edf3FirmwareArtifact? Tff7b72= Te6edf3performUpdateTb4b4b4(
Te6edf3release Tff7b72= Te6edf3releaseTb4b4b4,
Te6edf3hardware Tff7b72= Te6edf3hardwareTb4b4b4,
Te6edf3updateState Tff7b72= Te6edf3updateStateTb4b4b4,
Te6edf3firmwareUri Tff7b72= Te6edf3firmwareUriTb4b4b4,
Te6edf3transportFactory Tff7b72= Tb4b4b4{ Te6edf3BleOtaTransportTb4b4b4(Te6edf3bleScannerTb4b4b4, Te6edf3bleConnectionFactoryTb4b4b4, Te6edf3addressTb4b4b4, Te6edf3dispatchersTb4b4b4.Te6edf3defaultTb4b4b4) Tb4b4b4}Tb4b4b4,
Te6edf3rebootMode Tff7b72= T79c0ff1Tb4b4b4,
Te6edf3connectionAttempts Tff7b72= T79c0ff5Tb4b4b4,
Tb4b4b4)
Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffstartWifiUpdateTb4b4b4(
Te6edf3releaseTb4b4b4: Te6edf3FirmwareReleaseTb4b4b4,
Te6edf3hardwareTb4b4b4: Te6edf3DeviceHardwareTb4b4b4,
Te6edf3deviceIpTb4b4b4: Tffa657StringTb4b4b4,
Te6edf3updateStateTb4b4b4: Tb4b4b4(Te6edf3FirmwareUpdateStateTb4b4b4) Tff7b72-Tff7b72> Tffa657UnitTb4b4b4,
Te6edf3firmwareUriTb4b4b4: Te6edf3CommonUri? Tff7b72= Tff7b72nullTb4b4b4,
Tb4b4b4)Tb4b4b4: Te6edf3FirmwareArtifact? Tff7b72= Te6edf3performUpdateTb4b4b4(
Te6edf3release Tff7b72= Te6edf3releaseTb4b4b4,
Te6edf3hardware Tff7b72= Te6edf3hardwareTb4b4b4,
Te6edf3updateState Tff7b72= Te6edf3updateStateTb4b4b4,
Te6edf3firmwareUri Tff7b72= Te6edf3firmwareUriTb4b4b4,
Te6edf3transportFactory Tff7b72= Tb4b4b4{ Te6edf3WifiOtaTransportTb4b4b4(Te6edf3deviceIpTb4b4b4, Te6edf3WifiOtaTransportTb4b4b4.Te6edf3DEFAULT_PORTTb4b4b4) Tb4b4b4}Tb4b4b4,
Te6edf3rebootMode Tff7b72= T79c0ff2Tb4b4b4,
Te6edf3connectionAttempts Tff7b72= T79c0ff1T79c0ff0Tb4b4b4,
Tb4b4b4)
Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffperformUpdateTb4b4b4(
Te6edf3releaseTb4b4b4: Te6edf3FirmwareReleaseTb4b4b4,
Te6edf3hardwareTb4b4b4: Te6edf3DeviceHardwareTb4b4b4,
Te6edf3updateStateTb4b4b4: Tb4b4b4(Te6edf3FirmwareUpdateStateTb4b4b4) Tff7b72-Tff7b72> Tffa657UnitTb4b4b4,
Te6edf3firmwareUriTb4b4b4: Te6edf3CommonUri?Tb4b4b4,
Te6edf3transportFactoryTb4b4b4: Tb4b4b4(Tb4b4b4) Tff7b72-Tff7b72> Te6edf3UnifiedOtaProtocolTb4b4b4,
Te6edf3rebootModeTb4b4b4: Tffa657IntTb4b4b4,
Te6edf3connectionAttemptsTb4b4b4: Tffa657IntTb4b4b4,
Tb4b4b4)Tb4b4b4: Te6edf3FirmwareArtifact? Tb4b4b4{
Tff7b72var Te6edf3cleanupArtifactTb4b4b4: Te6edf3FirmwareArtifact? Tff7b72= Tff7b72null
Tff7b72return Tff7b72try Tb4b4b4{
Te6edf3withContextTb4b4b4(Te6edf3ioDispatcherTb4b4b4) Tb4b4b4{
T8b949e// Step 1: Get firmware file
Te6edf3cleanupArtifact Tff7b72= Te6edf3obtainFirmwareFileTb4b4b4(Te6edf3releaseTb4b4b4, Te6edf3hardwareTb4b4b4, Te6edf3firmwareUriTb4b4b4, Te6edf3updateStateTb4b4b4)
Tff7b72val Te6edf3firmwareFile Tff7b72= Te6edf3cleanupArtifact Tff7b72?: Tff7b72returnTf0883e@withContext Tff7b72null
T8b949e// Step 2: Read firmware once and calculate hash
Tff7b72val Te6edf3firmwareBytes Tff7b72= Te6edf3firmwareFileHandlerTb4b4b4.Te6edf3readBytesTb4b4b4(Te6edf3firmwareFileTb4b4b4)
Tff7b72val Te6edf3sha256Bytes Tff7b72= Te6edf3FirmwareHashUtilTb4b4b4.Te6edf3calculateSha256BytesTb4b4b4(Te6edf3firmwareBytesTb4b4b4)
Tff7b72val Te6edf3sha256Hash Tff7b72= Te6edf3FirmwareHashUtilTb4b4b4.Te6edf3bytesToHexTb4b4b4(Te6edf3sha256BytesTb4b4b4)
Te6edf3LoggerTb4b4b4.Te6edf3i Tb4b4b4{ Ta5d6ff"Ta5d6ffESP32 OTA: Firmware hash: Tffd700$Te6edf3sha256HashTa5d6ff (Tffd700${Te6edf3firmwareBytesTb4b4b4.Te6edf3sizeTffd700}Ta5d6ff bytes)Ta5d6ff" Tb4b4b4}
Te6edf3triggerRebootOtaTb4b4b4(Te6edf3rebootModeTb4b4b4, Te6edf3sha256BytesTb4b4b4)
T8b949e// Step 3: Wait for packet to be sent, then disconnect mesh service
T8b949e// The packet needs ~1-2 seconds to be written and acknowledged over BLE
Te6edf3delayTb4b4b4(Te6edf3PACKET_SEND_DELAY_MSTb4b4b4)
Te6edf3disconnectMeshServiceTb4b4b4(Tb4b4b4)
T8b949e// Give BLE stack time to fully release the GATT connection
Te6edf3delayTb4b4b4(Te6edf3GATT_RELEASE_DELAY_MSTb4b4b4)
Tff7b72val Te6edf3transport Tff7b72= Te6edf3transportFactoryTb4b4b4(Tb4b4b4)
Te6edf3connectToDeviceTb4b4b4(Te6edf3transportTb4b4b4, Te6edf3connectionAttemptsTb4b4b4, Te6edf3updateStateTb4b4b4)
Tff7b72try Tb4b4b4{
Te6edf3executeOtaSequenceTb4b4b4(Te6edf3transportTb4b4b4, Te6edf3firmwareBytesTb4b4b4, Te6edf3sha256HashTb4b4b4, Te6edf3rebootModeTb4b4b4, Te6edf3updateStateTb4b4b4)
Te6edf3firmwareFile
Tb4b4b4} Tff7b72finally Tb4b4b4{
Te6edf3transportTb4b4b4.Te6edf3closeTb4b4b4(Tb4b4b4)
Tb4b4b4}
Tb4b4b4}
Tb4b4b4} Tff7b72catch Tb4b4b4(Te6edf3eTb4b4b4: Te6edf3CancellationExceptionTb4b4b4) Tb4b4b4{
Tff7b72throw Te6edf3e
Tb4b4b4} Tff7b72catch Tb4b4b4(Te6edf3eTb4b4b4: Te6edf3OtaProtocolExceptionTb4b4b4.Te6edf3HashRejectedTb4b4b4) Tb4b4b4{
Te6edf3LoggerTb4b4b4.Te6edf3eTb4b4b4(Te6edf3eTb4b4b4) Tb4b4b4{ Ta5d6ff"Ta5d6ffESP32 OTA: Hash rejected by deviceTa5d6ff" Tb4b4b4}
Te6edf3updateStateTb4b4b4(Te6edf3FirmwareUpdateStateTb4b4b4.Te6edf3ErrorTb4b4b4(Te6edf3UiTextTb4b4b4.Te6edf3ResourceTb4b4b4(Te6edf3ResTb4b4b4.Te6edf3stringTb4b4b4.Te6edf3firmware_update_hash_rejectedTb4b4b4)Tb4b4b4)Tb4b4b4)
Te6edf3cleanupArtifact
Tb4b4b4} Tff7b72catch Tb4b4b4(Te6edf3eTb4b4b4: Te6edf3OtaProtocolExceptionTb4b4b4) Tb4b4b4{
Te6edf3LoggerTb4b4b4.Te6edf3eTb4b4b4(Te6edf3eTb4b4b4) Tb4b4b4{ Ta5d6ff"Ta5d6ffESP32 OTA: Protocol errorTa5d6ff" Tb4b4b4}
Te6edf3updateStateTb4b4b4(
Te6edf3FirmwareUpdateStateTb4b4b4.Te6edf3ErrorTb4b4b4(Te6edf3UiTextTb4b4b4.Te6edf3ResourceTb4b4b4(Te6edf3ResTb4b4b4.Te6edf3stringTb4b4b4.Te6edf3firmware_update_ota_failedTb4b4b4, Te6edf3eTb4b4b4.Te6edf3message Tff7b72?: Ta5d6ff"Ta5d6ff"Tb4b4b4)Tb4b4b4)Tb4b4b4,
Tb4b4b4)
Te6edf3cleanupArtifact
Tb4b4b4} Tff7b72catch Tb4b4b4(Tf0883e@SuppressTb4b4b4(Ta5d6ff"Ta5d6ffTooGenericExceptionCaughtTa5d6ff"Tb4b4b4) Te6edf3eTb4b4b4: Te6edf3ExceptionTb4b4b4) Tb4b4b4{
Te6edf3LoggerTb4b4b4.Te6edf3eTb4b4b4(Te6edf3eTb4b4b4) Tb4b4b4{ Ta5d6ff"Ta5d6ffESP32 OTA: Unexpected errorTa5d6ff" Tb4b4b4}
Te6edf3updateStateTb4b4b4(
Te6edf3FirmwareUpdateStateTb4b4b4.Te6edf3ErrorTb4b4b4(Te6edf3UiTextTb4b4b4.Te6edf3ResourceTb4b4b4(Te6edf3ResTb4b4b4.Te6edf3stringTb4b4b4.Te6edf3firmware_update_ota_failedTb4b4b4, Te6edf3eTb4b4b4.Te6edf3message Tff7b72?: Ta5d6ff"Ta5d6ff"Tb4b4b4)Tb4b4b4)Tb4b4b4,
Tb4b4b4)
Te6edf3cleanupArtifact
Tb4b4b4}
Tb4b4b4}
Tff7b72private Tff7b72suspend Tff7b72fun Td2a8fftriggerRebootOtaTb4b4b4(Te6edf3modeTb4b4b4: Tffa657IntTb4b4b4, Te6edf3hashTb4b4b4: Te6edf3ByteArray?Tb4b4b4) Tb4b4b4{
Tff7b72val Te6edf3myInfo Tff7b72= Te6edf3nodeRepositoryTb4b4b4.Te6edf3myNodeInfoTb4b4b4.Te6edf3value Tff7b72?: Tff7b72return
Tff7b72val Te6edf3myNodeNum Tff7b72= Te6edf3myInfoTb4b4b4.Te6edf3myNodeNum
Te6edf3LoggerTb4b4b4.Te6edf3i Tb4b4b4{ Ta5d6ff"Ta5d6ffESP32 OTA: Triggering reboot OTA mode Tffd700$Te6edf3modeTa5d6ff with hashTa5d6ff" Tb4b4b4}
Te6edf3radioControllerTb4b4b4.Te6edf3requestRebootOtaTb4b4b4(Te6edf3radioControllerTb4b4b4.Te6edf3getPacketIdTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3myNodeNumTb4b4b4, Te6edf3modeTb4b4b4, Te6edf3hashTb4b4b4)
Tb4b4b4}
T8b949e/**
* Disconnect the mesh service BLE connection to free up the GATT for OTA. Setting device address to "n" (NOP
* interface) cleanly disconnects without reconnection attempts.
*/
Tff7b72private Tff7b72fun Td2a8ffdisconnectMeshServiceTb4b4b4(Tb4b4b4) Tb4b4b4{
Te6edf3LoggerTb4b4b4.Te6edf3i Tb4b4b4{ Ta5d6ff"Ta5d6ffESP32 OTA: Disconnecting mesh service for OTATa5d6ff" Tb4b4b4}
Te6edf3radioControllerTb4b4b4.Te6edf3setDeviceAddressTb4b4b4(Ta5d6ff"Ta5d6ffnTa5d6ff"Tb4b4b4)
Tb4b4b4}
Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffobtainFirmwareFileTb4b4b4(
Te6edf3releaseTb4b4b4: Te6edf3FirmwareReleaseTb4b4b4,
Te6edf3hardwareTb4b4b4: Te6edf3DeviceHardwareTb4b4b4,
Te6edf3firmwareUriTb4b4b4: Te6edf3CommonUri?Tb4b4b4,
Te6edf3updateStateTb4b4b4: Tb4b4b4(Te6edf3FirmwareUpdateStateTb4b4b4) Tff7b72-Tff7b72> Tffa657UnitTb4b4b4,
Tb4b4b4)Tb4b4b4: Te6edf3FirmwareArtifact? Tb4b4b4{
Tff7b72val Te6edf3downloadingMsg Tff7b72= Te6edf3getStringSuspendTb4b4b4(Te6edf3ResTb4b4b4.Te6edf3stringTb4b4b4.Te6edf3firmware_update_downloading_percentTb4b4b4, T79c0ff0Tb4b4b4)Tb4b4b4.Te6edf3stripFormatArgsTb4b4b4(Tb4b4b4)
Te6edf3updateStateTb4b4b4(
Te6edf3FirmwareUpdateStateTb4b4b4.Te6edf3DownloadingTb4b4b4(
Te6edf3ProgressStateTb4b4b4(Te6edf3message Tff7b72= Te6edf3UiTextTb4b4b4.Te6edf3DynamicStringTb4b4b4(Te6edf3downloadingMsgTb4b4b4)Tb4b4b4, Te6edf3progress Tff7b72= T79c0ff0fTb4b4b4)Tb4b4b4,
Tb4b4b4)Tb4b4b4,
Tb4b4b4)
Tff7b72return Tff7b72if Tb4b4b4(Te6edf3firmwareUri Tff7b72!Tff7b72= Tff7b72nullTb4b4b4) Tb4b4b4{
Te6edf3updateStateTb4b4b4(
Te6edf3FirmwareUpdateStateTb4b4b4.Te6edf3ProcessingTb4b4b4(
Te6edf3ProgressStateTb4b4b4(Te6edf3message Tff7b72= Te6edf3UiTextTb4b4b4.Te6edf3ResourceTb4b4b4(Te6edf3ResTb4b4b4.Te6edf3stringTb4b4b4.Te6edf3firmware_update_extractingTb4b4b4)Tb4b4b4)Tb4b4b4,
Tb4b4b4)Tb4b4b4,
Tb4b4b4)
Te6edf3firmwareFileHandlerTb4b4b4.Te6edf3importFromUriTb4b4b4(Te6edf3firmwareUriTb4b4b4)
Tb4b4b4} Tff7b72else Tb4b4b4{
Tff7b72val Te6edf3firmwareFile Tff7b72=
Te6edf3firmwareRetrieverTb4b4b4.Te6edf3retrieveEsp32FirmwareTb4b4b4(Te6edf3releaseTb4b4b4, Te6edf3hardwareTb4b4b4) Tb4b4b4{ Te6edf3progress Tff7b72-Tff7b72>
Tff7b72val Te6edf3percent Tff7b72= Tb4b4b4(Te6edf3progress Tff7b72* Te6edf3PERCENT_MAXTb4b4b4)Tb4b4b4.Te6edf3toIntTb4b4b4(Tb4b4b4)
Te6edf3updateStateTb4b4b4(
Te6edf3FirmwareUpdateStateTb4b4b4.Te6edf3DownloadingTb4b4b4(
Te6edf3ProgressStateTb4b4b4(
Te6edf3message Tff7b72= Te6edf3UiTextTb4b4b4.Te6edf3DynamicStringTb4b4b4(Te6edf3downloadingMsgTb4b4b4)Tb4b4b4,
Te6edf3progress Tff7b72= Te6edf3progressTb4b4b4,
Te6edf3details Tff7b72= Ta5d6ff"Tffd700$Te6edf3percentTa5d6ff%Ta5d6ff"Tb4b4b4,
Tb4b4b4)Tb4b4b4,
Tb4b4b4)Tb4b4b4,
Tb4b4b4)
Tb4b4b4}
Tff7b72if Tb4b4b4(Te6edf3firmwareFile Tff7b72=Tff7b72= Tff7b72nullTb4b4b4) Tb4b4b4{
Te6edf3updateStateTb4b4b4(
Te6edf3FirmwareUpdateStateTb4b4b4.Te6edf3ErrorTb4b4b4(
Te6edf3UiTextTb4b4b4.Te6edf3ResourceTb4b4b4(Te6edf3ResTb4b4b4.Te6edf3stringTb4b4b4.Te6edf3firmware_update_not_found_in_releaseTb4b4b4, Te6edf3hardwareTb4b4b4.Te6edf3displayNameTb4b4b4)Tb4b4b4,
Tb4b4b4)Tb4b4b4,
Tb4b4b4)
Tff7b72null
Tb4b4b4} Tff7b72else Tb4b4b4{
Te6edf3firmwareFile
Tb4b4b4}
Tb4b4b4}
Tb4b4b4}
Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffconnectToDeviceTb4b4b4(
Te6edf3transportTb4b4b4: Te6edf3UnifiedOtaProtocolTb4b4b4,
Te6edf3attemptsTb4b4b4: Tffa657IntTb4b4b4,
Te6edf3updateStateTb4b4b4: Tb4b4b4(Te6edf3FirmwareUpdateStateTb4b4b4) Tff7b72-Tff7b72> Tffa657UnitTb4b4b4,
Tb4b4b4) Tb4b4b4{
T8b949e// Show "waiting for reboot" state before first connection attempt
Te6edf3updateStateTb4b4b4(
Te6edf3FirmwareUpdateStateTb4b4b4.Te6edf3ProcessingTb4b4b4(Te6edf3ProgressStateTb4b4b4(Te6edf3UiTextTb4b4b4.Te6edf3ResourceTb4b4b4(Te6edf3ResTb4b4b4.Te6edf3stringTb4b4b4.Te6edf3firmware_update_waiting_rebootTb4b4b4)Tb4b4b4)Tb4b4b4)Tb4b4b4,
Tb4b4b4)
Tff7b72for Tb4b4b4(Te6edf3i Tff7b72in T79c0ff1.Tb4b4b4.Te6edf3attemptsTb4b4b4) Tb4b4b4{
Tff7b72try Tb4b4b4{
Te6edf3updateStateTb4b4b4(
Te6edf3FirmwareUpdateStateTb4b4b4.Te6edf3ProcessingTb4b4b4(
Te6edf3ProgressStateTb4b4b4(Te6edf3UiTextTb4b4b4.Te6edf3ResourceTb4b4b4(Te6edf3ResTb4b4b4.Te6edf3stringTb4b4b4.Te6edf3firmware_update_connecting_attemptTb4b4b4, Te6edf3iTb4b4b4, Te6edf3attemptsTb4b4b4)Tb4b4b4)Tb4b4b4,
Tb4b4b4)Tb4b4b4,
Tb4b4b4)
Te6edf3transportTb4b4b4.Te6edf3connectTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getOrThrowTb4b4b4(Tb4b4b4)
Tff7b72return
Tb4b4b4} Tff7b72catch Tb4b4b4(Tf0883e@SuppressTb4b4b4(Ta5d6ff"Ta5d6ffTooGenericExceptionCaughtTa5d6ff"Tb4b4b4) Te6edf3eTb4b4b4: Te6edf3ExceptionTb4b4b4) Tb4b4b4{
Tff7b72if Tb4b4b4(Te6edf3i Tff7b72=Tff7b72= Te6edf3attemptsTb4b4b4) Tff7b72throw Te6edf3e
Te6edf3delayTb4b4b4(Te6edf3RETRY_DELAYTb4b4b4)
Tb4b4b4}
Tb4b4b4}
Tb4b4b4}
Tf0883e@SuppressTb4b4b4(Ta5d6ff"Ta5d6ffLongMethodTa5d6ff"Tb4b4b4)
Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffexecuteOtaSequenceTb4b4b4(
Te6edf3transportTb4b4b4: Te6edf3UnifiedOtaProtocolTb4b4b4,
Te6edf3firmwareDataTb4b4b4: Te6edf3ByteArrayTb4b4b4,
Te6edf3sha256HashTb4b4b4: Tffa657StringTb4b4b4,
Te6edf3rebootModeTb4b4b4: Tffa657IntTb4b4b4,
Te6edf3updateStateTb4b4b4: Tb4b4b4(Te6edf3FirmwareUpdateStateTb4b4b4) Tff7b72-Tff7b72> Tffa657UnitTb4b4b4,
Tb4b4b4) Tb4b4b4{
Tff7b72val Te6edf3fileSize Tff7b72= Te6edf3firmwareDataTb4b4b4.Te6edf3sizeTb4b4b4.Te6edf3toLongTb4b4b4(Tb4b4b4)
T8b949e// Start OTA handshake
Te6edf3updateStateTb4b4b4(
Te6edf3FirmwareUpdateStateTb4b4b4.Te6edf3ProcessingTb4b4b4(Te6edf3ProgressStateTb4b4b4(Te6edf3UiTextTb4b4b4.Te6edf3ResourceTb4b4b4(Te6edf3ResTb4b4b4.Te6edf3stringTb4b4b4.Te6edf3firmware_update_starting_otaTb4b4b4)Tb4b4b4)Tb4b4b4)Tb4b4b4,
Tb4b4b4)
Te6edf3transport
Tb4b4b4.Te6edf3startOtaTb4b4b4(Te6edf3sizeBytes Tff7b72= Te6edf3fileSizeTb4b4b4, Te6edf3sha256Hash Tff7b72= Te6edf3sha256HashTb4b4b4) Tb4b4b4{ Te6edf3status Tff7b72-Tff7b72>
Tff7b72when Tb4b4b4(Te6edf3statusTb4b4b4) Tb4b4b4{
Te6edf3OtaHandshakeStatusTb4b4b4.Te6edf3Erasing Tff7b72-Tff7b72> Tb4b4b4{
Te6edf3updateStateTb4b4b4(
Te6edf3FirmwareUpdateStateTb4b4b4.Te6edf3ProcessingTb4b4b4(
Te6edf3ProgressStateTb4b4b4(Te6edf3UiTextTb4b4b4.Te6edf3ResourceTb4b4b4(Te6edf3ResTb4b4b4.Te6edf3stringTb4b4b4.Te6edf3firmware_update_erasingTb4b4b4)Tb4b4b4)Tb4b4b4,
Tb4b4b4)Tb4b4b4,
Tb4b4b4)
Tb4b4b4}
Tb4b4b4}
Tb4b4b4}
Tb4b4b4.Te6edf3getOrThrowTb4b4b4(Tb4b4b4)
T8b949e// Stream firmware data
Tff7b72val Te6edf3uploadingMsg Tff7b72= Te6edf3UiTextTb4b4b4.Te6edf3ResourceTb4b4b4(Te6edf3ResTb4b4b4.Te6edf3stringTb4b4b4.Te6edf3firmware_update_uploadingTb4b4b4)
Te6edf3updateStateTb4b4b4(Te6edf3FirmwareUpdateStateTb4b4b4.Te6edf3UpdatingTb4b4b4(Te6edf3ProgressStateTb4b4b4(Te6edf3uploadingMsgTb4b4b4, T79c0ff0fTb4b4b4)Tb4b4b4)Tb4b4b4)
Tff7b72val Te6edf3chunkSize Tff7b72=
Tff7b72if Tb4b4b4(Te6edf3rebootMode Tff7b72=Tff7b72= T79c0ff1Tb4b4b4) Tb4b4b4{
Te6edf3BleOtaTransportTb4b4b4.Te6edf3RECOMMENDED_CHUNK_SIZE
Tb4b4b4} Tff7b72else Tb4b4b4{
Te6edf3WifiOtaTransportTb4b4b4.Te6edf3RECOMMENDED_CHUNK_SIZE
Tb4b4b4}
Tff7b72val Te6edf3throughputTracker Tff7b72= Te6edf3ThroughputTrackerTb4b4b4(Tb4b4b4)
Te6edf3transport
Tb4b4b4.Te6edf3streamFirmwareTb4b4b4(
Te6edf3data Tff7b72= Te6edf3firmwareDataTb4b4b4,
Te6edf3chunkSize Tff7b72= Te6edf3chunkSizeTb4b4b4,
Te6edf3onProgress Tff7b72= Tb4b4b4{ Te6edf3progress Tff7b72-Tff7b72>
Tff7b72val Te6edf3bytesSent Tff7b72= Tb4b4b4(Te6edf3progress Tff7b72* Te6edf3firmwareDataTb4b4b4.Te6edf3sizeTb4b4b4)Tb4b4b4.Te6edf3toLongTb4b4b4(Tb4b4b4)
Te6edf3throughputTrackerTb4b4b4.Te6edf3recordTb4b4b4(Te6edf3bytesSentTb4b4b4)
Tff7b72val Te6edf3percent Tff7b72= Tb4b4b4(Te6edf3progress Tff7b72* Te6edf3PERCENT_MAXTb4b4b4)Tb4b4b4.Te6edf3toIntTb4b4b4(Tb4b4b4)
Tff7b72val Te6edf3bytesPerSecond Tff7b72= Te6edf3throughputTrackerTb4b4b4.Te6edf3bytesPerSecondTb4b4b4(Tb4b4b4)
Tff7b72val Te6edf3speedText Tff7b72=
Tff7b72if Tb4b4b4(Te6edf3bytesPerSecond Tff7b72> T79c0ff0Tb4b4b4) Tb4b4b4{
Tff7b72val Te6edf3kibPerSecond Tff7b72= Te6edf3bytesPerSecondTb4b4b4.Te6edf3toFloatTb4b4b4(Tb4b4b4) Tff7b72/ Te6edf3KIB_DIVISOR
Tff7b72val Te6edf3remainingBytes Tff7b72= Te6edf3firmwareDataTb4b4b4.Te6edf3size Tff7b72- Te6edf3bytesSent
Tff7b72val Te6edf3etaSeconds Tff7b72= Te6edf3remainingBytesTb4b4b4.Te6edf3toFloatTb4b4b4(Tb4b4b4) Tff7b72/ Te6edf3bytesPerSecond
Ta5d6ff"Tffd700${Te6edf3NumberFormatterTb4b4b4.Te6edf3formatTb4b4b4(Te6edf3kibPerSecondTb4b4b4, T79c0ff1Tb4b4b4)Tffd700}Ta5d6ff KiB/s, ETA: Tffd700${Te6edf3etaSecondsTb4b4b4.Te6edf3toIntTb4b4b4(Tb4b4b4)Tffd700}Ta5d6ffsTa5d6ff"
Tb4b4b4} Tff7b72else Tb4b4b4{
Ta5d6ff"Ta5d6ff"
Tb4b4b4}
Te6edf3updateStateTb4b4b4(
Te6edf3FirmwareUpdateStateTb4b4b4.Te6edf3UpdatingTb4b4b4(
Te6edf3ProgressStateTb4b4b4(
Te6edf3message Tff7b72= Te6edf3uploadingMsgTb4b4b4,
Te6edf3progress Tff7b72= Te6edf3progressTb4b4b4,
Te6edf3details Tff7b72= Ta5d6ff"Tffd700$Te6edf3percentTa5d6ff% (Tffd700$Te6edf3speedTextTa5d6ff)Ta5d6ff"Tb4b4b4,
Tb4b4b4)Tb4b4b4,
Tb4b4b4)Tb4b4b4,
Tb4b4b4)
Tb4b4b4}Tb4b4b4,
Tb4b4b4)
Tb4b4b4.Te6edf3getOrThrowTb4b4b4(Tb4b4b4)
Te6edf3LoggerTb4b4b4.Te6edf3i Tb4b4b4{ Ta5d6ff"Ta5d6ffESP32 OTA: Firmware stream completedTa5d6ff" Tb4b4b4}
Te6edf3updateStateTb4b4b4(Te6edf3FirmwareUpdateStateTb4b4b4.Te6edf3SuccessTb4b4b4)
Tb4b4b4}
Tb4b4b4}
Served by rngit 1.5.0 - Generated in 0.09s